package com.flink;

import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class CheckPointMain {

    public static void main(String[] args) throws Exception {
        ParameterTool tool = ParameterTool.fromArgs(args);
        String index = tool.get("index");

        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        switch (index) {
            case "1": {
                Step.step01(env);
                break;
            }
            case "2": {
                Step.step02(env);
                break;
            }
            case "3": {
                Step.step03(env);
                break;
            }
        }


        env.execute();
    }


}
